package com.example.util;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.util.UUID;

public class MySQLInsertWithDelay {
    public static void main(String[] args) {
        // 数据库连接信息  
        String url = "jdbc:mysql://10.13.10.28:8000/szx";
        String user = "root";
        String password = "Gzmt@2024";

        // SQL插入语句  
        String sql = "INSERT INTO user1 VALUES (?, ?)";

        try (Connection conn = DriverManager.getConnection(url, user, password);
             PreparedStatement pstmt = conn.prepareStatement(sql)) {

            // 假设我们要插入10行数据  
            for (int i = 1; i < 101; i++) {
                // 生成UUID  
                String id=Integer.toString(i+4000);
                // 假设每行插入的数据只是简单的'Row ' + i  
                String data = "rds insert: " + i;

                // 设置PreparedStatement的参数  
                pstmt.setString(1, id);
                pstmt.setString(2, data);

                // 执行插入  
                pstmt.executeUpdate();

                // 等待2秒  
                Thread.sleep(2000);

                System.out.println("Inserted row " + i);
            }

            // 提交事务（如果数据库自动提交被关闭的话）  
            conn.commit();

        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}